package com.qidian.buy.config.mqdemo;

import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * @author 戴着假发的程序员
 * @company 起点编程
 * @date 2023/9/15 9:16
 */
@Configuration
public class QueueConfig {
    @Bean
    public Queue stQueueA(){
        return  new Queue("stQueueA",false);
    }


    @Bean
    public Queue pojoQueue(){
        return  new Queue("queue-pojo",false);
    }
    @Bean
    public Queue simplQueue(){
        // 创建一个队列
        // 参数1：队列的名字，也是这个队列的唯一标志。
        // 参数2: 表示这个队列的消息是否需要持久化存储。
        return  new Queue("simple-queue",true);
    }
}
